package com.huitian.net.pipeline

import org.apache.spark.sql.{DataFrame, SparkSession}



trait EnSource[M] {
  def read(): DataFrame
}

trait GxSparkSession[M] {
  def session(): SparkSession
}
